package com.k.activemq.openwire_sync1.listener;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Session;

public abstract class AbstractMessageListener implements MessageListener {
    private Session session;
    public AbstractMessageListener(Session session){
        this.session = session;
    }
    abstract void onMessage(Session session, Message var1);

    @Override
    public void onMessage(Message message) {
        onMessage(session,message);
    }
}
